package org.lzfto.flink.demo.business.flinkTest.flinkObjects.source.clickdemo;

import java.nio.charset.StandardCharsets;

import org.apache.flink.api.connector.source.SourceSplit;

/**
*
*@author lzfto
*@创建时间 2025年7月9日 11:17:54
*/
public class ClickEventSplit implements SourceSplit {

	private final String id;
	
	@Override
	public String splitId() {
		return id;
	}
	
	public ClickEventSplit(String id) {
		this.id=id;
	}
	
	@Override
    public String toString() {
		return this.id;
	}

	public byte[] serialize() {
        return toString().getBytes(StandardCharsets.UTF_8);
    }
}
